package com.base.taskreports.task.job;

import org.springframework.beans.factory.annotation.Autowired;

import com.base.taskreports.task.service.JfsService;
import com.base.taskreports.task.service.TimedTaskService;
import com.base.taskreports.task.service.UserSalveService;
import com.vip.saturn.job.AbstractSaturnJavaJob;
import com.vip.saturn.job.SaturnJobExecutionContext;
import com.vip.saturn.job.SaturnJobReturn;

public class JfsJob extends AbstractSaturnJavaJob {

	@Autowired
	private JfsService JfsService;
	
	@Override
	public SaturnJobReturn handleJavaJob(String jobName, Integer shardItem, String shardParam,
			SaturnJobExecutionContext shardingContext) throws InterruptedException {
		
		String DateTime = shardingContext.getJobParameter();
		//String DateTime = null;
		
		//非货币积分发放金额浮动比率
	    JfsService.getJFS_M001( DateTime);
	    
	    // 非人民币货币积分发放金额浮动比率
	    JfsService.getJFS_M002( DateTime);

	    // 事后结算积分发放金额浮动比率
	    JfsService.getJFS_M003( DateTime);

	    // 单用户货币积分余额> N浮动比率
	    JfsService.getJFS_M004( DateTime);

	    // 单用户非货币积分余额> N浮动比率
	    JfsService.getJFS_M005( DateTime);

	    // 临时用户（非注册用户,即不使用userID用户）交易数量浮动比										
	    JfsService.getJFS_M006( DateTime);

	    // 积分余额为负数量				
	    JfsService.getJFS_M007( DateTime);



		return new SaturnJobReturn("I am the return result of shard item " + shardItem);
	}

}
